37d87820bb39a32518afddc160eb85b135051ceb,frameworks/helloworld/src/test/java/com/mesosphere/sdk/helloworld/scheduler/ServiceSpecTest.java,ServiceSpecTest,ServiceSpecValidation,#String#,109
Before Change
TestingServer testingServer = new TestingServer();
StateStoreCache.resetInstanceForTests();
StateStore stateStore = DefaultScheduler.createStateStore(
serviceSpec,
testingServer.getConnectString());
ConfigStore<ServiceSpec> configStore = DefaultScheduler.createConfigStore(
serviceSpec,
testingServer.getConnectString(),
Collections.emptyList());
ConfigurationUpdater.UpdateResult configUpdateResult =
DefaultScheduler.updateConfig(serviceSpec, stateStore, configStore);
OfferRequirementProvider offerRequirementProvider =
DefaultScheduler.createOfferRequirementProvider(stateStore, configUpdateResult.targetId);
DefaultScheduler.create(serviceSpec, stateStore, configStore, offerRequirementProvider);
}
}
After Change
private void validateServiceSpec(String fileName) throws Exception {
File file = new File(getClass().getClassLoader().getResource(fileName).getFile());
DefaultServiceSpec serviceSpec = YAMLServiceSpecFactory.generateServiceSpec(generateRawSpecFromYAML(file));
TestingServer testingServer = new TestingServer();
StateStoreCache.resetInstanceForTests();
DefaultScheduler.newBuilder(serviceSpec)
.setStateStore(DefaultScheduler.createStateStore(serviceSpec, testingServer.getConnectString()))
.setConfigStore(DefaultScheduler.createConfigStore(serviceSpec, testingServer.getConnectString()))
.build();
testingServer.close();
}
}